package com.liu.pool_study.diyPool;

import java.util.Collection;
import java.util.Collections;
import java.util.LinkedList;
import java.util.List;

/**
 * 线程池类
 * 1.任务队列
 * 2.当前线程数量
 * 3.核心线程数量
 * 4.最大线程数量
 * 5.任务队列的长度
 * 方法
 *      1.提交方法
 *      将任务添加到集合中，需要判断是否超出了任务长度
 *      2.执行方法
 *      判断当前线程的数量，决定创建核心线程还是非核心线程
 */
public class MyThreadPool {

    //1.任务队列
    private List<Runnable> tasks = Collections.synchronizedList(new LinkedList<>());
    //2.当前线程数量
    private int num;
    //3.核心线程数量
    private int corePoolSize;
    //4.最大线程数量
    private int maxSize;
    //5.任务队列长度
    private int workSize;

    public MyThreadPool(int corePoolSize, int maxSize, int workSize) {
        this.tasks = tasks;
        this.num = num;
        this.corePoolSize = corePoolSize;
        this.maxSize = maxSize;
        this.workSize = workSize;
    }

    //提交任务
    public void  submin(Runnable r){
        //判断当前集合中任务的数量是否超出了最大任务数量
        if(tasks.size() ==workSize){
            System.out.println("任务："+r + "被丢弃了。。。。");
        }else{
            tasks.add(r);
            //执行任务
            execTask(r);
        }

    }
    //执行任务
    private void execTask(Runnable r) {
        //判断当前线程池中的线程总数量，是否超出了核心数
        if(num < corePoolSize){
            new MyWork("核心线程"+num,tasks).start();
            num++;
        }else if (num < maxSize){
            new MyWork("非核心线程"+num,tasks).start();
            num++;
        }else{
            System.out.println("任务"+r+"被缓存了");
        }
    }
}
